package com.lifupeng.learn.alibaba.cloud.user.receiver;

import com.lifupeng.learn.alibaba.cloud.user.stream.InputMessageBinding;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

/**
 * @Description TODO
 * @Author FuPeng Li
 * @Date 2021/8/12
 **/
@EnableBinding(InputMessageBinding.class)
public class MessageCenterReceiver {

    @StreamListener(InputMessageBinding.INPUT)
    public void handle(String value){
        System.out.println("收到的消息："+value);
    }
}
